package com.yesep.learn.mqtt.protocol;

import io.netty.channel.Channel;
import io.netty.handler.codec.mqtt.MqttConnectMessage;

/**
   *   消息编号：1
 * @Description: 请求连接
 */
public interface IConnect {
	/**
	   *   连接处理
	 * @param channel
	 * @param msg
	 */
	public void process(Channel channel, MqttConnectMessage msg);
}
